package xmq

import (
	"context"
	"gitee.com/go-mid/infra/xmq/mqconf"
)

type MQReader interface {
	MQCloser
	ReadMsg(ctx context.Context, v interface{}) error
	FetchMsg(ctx context.Context, v interface{}) (mqconf.AckHandler, error)
}
